def init_redis(self):
        startup_nodes = [{'host': '10.110.223.93', 'port': 6379}]
        try:
            conn = RedisCluster(startup_nodes=startup_nodes,decode_responses=True, skip_full_coverage_check=True,password=None)
            res = BybitWebsocket(online).etpws()
            #r = conn.set("nav_test", res[0])
            # 需要先判断test_key是否为空，如果为空直接set  value，如果不为空对比（这我自己先写），不一样更新，一样抛异常
            test_key = "test"
            if conn.get(test_key) is None:
                test_val = json.dumps({"nav_test": res[0],"leverageRatio_test":res[1],"create_time":time.time()})
                r1 = conn.set(test_key,test_val)
            # else:
            #     if conn.get(test_key) ==

            # r2 = conn.set({'test-net'}:{"nav_testnet": res[0], "leverageRatio_testnet": res[1]})
            # r3 = conn.set({'online'}:{"nav_online": res[0], "leverageRatio_online": res[1]})
            test_val2 = conn.get(test_key)
            res2 = json.loads(test_val2)
            print(res2,type(res2))
            print(type(res2))
            print(res2["nav_test"])
            print(r1)
            print('连接成功！！！！！1', conn)
            return conn
        except Exception as e:
            print("connect error ", str(e))
            print('链接失败')